package com.hyw.trace.configuration.meta.mq.binder;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * 数据消息的源头, 一般由前置处理采集后, 放到数据源中, 参考{@link ZTraceSource}
 * 
 * @author hongyu
 */
public interface ZTraceSink {
  String INPUT = "ZTrace";

  @Input(INPUT)
  SubscribableChannel input();
}
